package com.gin.monitor.agg.utils;

import com.gin.monitor.agg.vo.MonitorInfo;
import com.gin.monitor.agg.vo.ViolationInfo;
import org.apache.flink.api.common.state.MapStateDescriptor;

/**
 * @author gin
 * @date 2021/4/30
 */
public class GlobalConstants {

    public static MapStateDescriptor<String, MonitorInfo> MONITOR_STATE_DESCRIPTOR =
            new MapStateDescriptor<>("monitor_info", String.class, MonitorInfo.class);

    public static MapStateDescriptor<String, ViolationInfo> VIOLATION_STATE_DESCRIPTOR =
            new MapStateDescriptor<>("monitor_info", String.class, ViolationInfo.class);

}
